    package com.atguigu.springcloud.service.impl;

    import com.atguigu.springcloud.service.IMessageProvide;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.cloud.stream.annotation.EnableBinding;
    import org.springframework.cloud.stream.messaging.Source;
    import org.springframework.messaging.MessageChannel;
    import org.springframework.messaging.support.MessageBuilder;

    import javax.annotation.Resource;
    import java.util.UUID;

    /**
     * @USER: dayu
     * @DATE: 2020/4/1
     * @DESCRIPTION:
     */
    @EnableBinding(Source.class)    //定义消息管道
    @Slf4j
    public class MessageProvideImpl implements IMessageProvide {

        @Resource
        MessageChannel output;  //消息发送通道

        @Override
        public String send() {
            String serial = UUID.randomUUID().toString();
            output.send(MessageBuilder.withPayload(serial).build());
            log.info("serial:"+serial);
            return serial;
        }
    }
